//package com.gzcstec.product.rabbitmq;
//
//import com.gzcstec.product.dataobject.DecreaseStockInput;
//import com.gzcstec.product.rabbitmq.client.MySink;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.cloud.stream.annotation.EnableBinding;
//import org.springframework.cloud.stream.annotation.StreamListener;
//
//@Slf4j
////@EnableBinding(value = {MySink.class})
//public class MyStreamReceiver {
//
////    @StreamListener(value = MySink.INPUT)
//    public void receive(DecreaseStockInput decreaseStockInput) {
//        log.info("receive，message={}" , decreaseStockInput);
//    }
//
////    @StreamListener(value = MySink.INPUT_PRODUCT)
//    public void receiveProduct(DecreaseStockInput decreaseStockInput) {
//        log.info("receiveProduct，message={}" , decreaseStockInput);
//    }
//
//}
